//package com.market.goods.comsumer.rocket;
//
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
//import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;
//import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
//import org.springframework.messaging.Message;
//
//
//@Slf4j
//@RocketMQTransactionListener
//public class TransactionListionerImpl implements RocketMQLocalTransactionListener {
//
//    @Override
//    public RocketMQLocalTransactionState executeLocalTransaction(Message message, Object object) {
//        log.info("executeLocalTransactionMessage={},Object={}",message,object);
//        return RocketMQLocalTransactionState.COMMIT;
//    }
//
//    @Override
//    public RocketMQLocalTransactionState checkLocalTransaction(Message message) {
//        log.info("checkLocalTransaction={}",message);
//        return RocketMQLocalTransactionState.COMMIT;
//    }
//}
